package io.gitee.kenewstar.dbmq;

import java.util.List;

/**
 * @author kenewstar
 */
public interface DbMqConsumerInf {

    /**
     * 消费者执行业务逻辑
     *
     * @param list 消息数据
     */
    void consume(List<Message> list);


}
